package byx.container.annotation.demo.PublishSubscribeDemo;

import byx.container.annotation.annotation.Register;

@Register
@Topic("sports")
public class SportsSubscriber1 implements Subscriber {
    @Override
    public void consume(String msg) {
        System.out.println("SportsSubscriber1: " + msg);
        Flag.set.add("SportsSubscriber1: " + msg);
    }
}
